package com.changgou.business.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

@Component
public class AdListener {


    @Autowired
    //这个类的作用是什么?????
    private RestTemplate restTemplate;

    //这是一个消费类,去获取到rabbitMq中队列的消息,然后再把这个消息发送给nginx,提示nginx进行预热,更新redis中的数据
    //定义监听的队列是ad_update-queue
    @RabbitListener(queues = "ad_update-queue")
    public void receiveMessage(String message){
        System.out.println("接受到的消息为:"+message);
        String url="http://192.168.200.128/ad_update?position="+message;
        //为什么他可以发起远程调用????????????,这个是把消息发送到nginx中,一个缓存预热的请求,让nginx执行缓存预热
        restTemplate.getForObject(url,String.class);
    }

    //发起远程调用




}
